#ifndef _THREAD_MSG_H_
#define _THREAD_MSG_H_
#include "common.h"
#include "libfyaml.h"
#include "main.h"
#include "mqtt_msg.h"
#include <chrono>
#include <pthread.h>
#include <thread>
#include <unistd.h>
#include "modbus.h"

using namespace mqtt;

extern void mqtt_msg_deal_thread(void);
extern void dev_write_queue_deal_thread(void);
extern void dev_read_queue_deal_thread(void);
extern void dev_auto_read_queue_deal_thread(void);
extern int dev_read_msg_pub(uint8_t idx);

#endif
